package com.duowan.realtime.dao;

import java.util.List;

import com.duowan.realtime.model.SqlJob;


/**
 * @version 1.0
 * @author: tangsicheng
 * @date: 14-8-6
 * @since 1.0
 */
public interface SqlJobDao {

    public void insert(SqlJob entity);

    public int deleteById(String sqlId);

    public SqlJob getSqlJobById(String sqlId);
    /**
     * @return List<SqlJob>
     * @Description: 获取所有的任务
     */
    public List<SqlJob> getSqlJobs();

    /**
     * @Description: 更新sqljob最后的error
     */
    public void updateJobError(String sqlIds, String errorMessage);


    public  SqlJob getSqlJobByQueryStatement(String squeryStatement);

    public int update(SqlJob entity);

}

